bfcb69a2a6a4f82bdec21c8811ac72460a0b5611,hazelcast/src/main/java/com/hazelcast/mapreduce/impl/task/JobSupervisor.java,JobSupervisor,cancel,#,211

Before Change


    public void cancel() {
        String jobId = getConfiguration().getJobId();
        jobTracker.unregisterTrackableJob(jobId);
        jobTracker.unregisterMapCombineTask(jobId);
        jobTracker.unregisterReducerTask(jobId);
        mapReduceService.destroyJobSupervisor(this);
    }

After Change


    public void cancel() {
        String jobId = getConfiguration().getJobId();
        jobTracker.unregisterTrackableJob(jobId);
        MapCombineTask mapCombineTask = jobTracker.unregisterMapCombineTask(jobId);
        if (mapCombineTask != null) {
            mapCombineTask.cancel();
        }
        ReducerTask reducerTask = jobTracker.unregisterReducerTask(jobId);
        if (reducerTask != null) {